package com.lwq.project.activemq.listener;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

import org.apache.log4j.Logger;

/**
* @author 作者 linweiqiang
* @version 创建时间：2017年10月20日 上午10:56:08
* 类说明
*/
public class TopicMessageListener implements MessageListener {

	public Logger logger = Logger.getLogger(TopicMessageListener.class);
	
	public void onMessage(Message message) {
			 TextMessage tm = (TextMessage) message;
			  try {
			   logger.error("TopicMessageListener监听到了文本消息：\t"
			     + tm.getText());
			   //do something ...
			  } catch (JMSException e) {
			   e.printStackTrace();
			  }
	}

}
